package com.mercury.kafka.domain;


import com.mercury.kafka.utils.IdUtils;
import lombok.Data;

import java.io.Serializable;


/**
 * 消息对象
 *
 * @author mercury
 */
@Data
public class KafKaMqMessage implements Serializable {

    /**
     * 消息Id
     */
    protected String id = IdUtils.randomUUID();

    /**
     * 消息内容
     */
    protected String data;


}